package com.binlog.core.handler;

import com.binlog.module.DatebaseInfo;
import com.binlog.util.MysqlUtils;
import org.apache.commons.lang3.StringUtils;

public class BackupInit {


    /**
     * 备份初始化
     * @param table
     * @param datebaseInfo
     */
    public void init(String table, String schema, DatebaseInfo datebaseInfo) {
        if (!datebaseInfo.isExitsDatebase() && StringUtils.isNotEmpty(datebaseInfo.getCreateDatebaseSql())) {
            MysqlUtils.executBackSql(datebaseInfo.getCreateDatebaseSql(), null);
        }
        if (!datebaseInfo.getExitsTable().getOrDefault(table, false) && StringUtils.isNotEmpty(
                datebaseInfo.getCreateTableSql().get(table)
        )) {
            MysqlUtils.executBackSql(datebaseInfo.getCreateTableSql().get(table), schema);
        }
    }
}
